package m3;

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.MessageProperties;

import java.util.Scanner;

public class Producer3 {
    public static void main(String[] args) throws Exception{
        //连接
        ConnectionFactory f = new ConnectionFactory();
        f.setHost("192.168.64.140");
        f.setPort(5672); //默认端口可以不用设置
        f.setUsername("admin");
        f.setPassword("admin");
        Connection con = f.newConnection(); //连接
        Channel c = con.createChannel(); //通道
        //创建队列 helloworld1
        //如果队列已经存在，不会重复创建
        //参数列表：        队列名，是否持久队列，是否排他队列（独占），是否自动删除，其他参数属性设置
        c.queueDeclare("task_queue",true,false,false,null);
        //向helloworld1队列发送消息
        //参数：           “”默认的交换机，队列名，消息的其他参数属性，发送的内容
        while (true){
            System.out.print("输入消息： ");
            String s = new Scanner(System.in).nextLine();
            c.basicPublish("","task_queue", MessageProperties.PERSISTENT_TEXT_PLAIN,s.getBytes("UTF-8"));
        }
    }
}
